/*
 * Licensed to the Deppon EXPRESS .
 */
package com.depponframework.rocketmq.spring.annotation;

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.Target;
import java.lang.annotation.RetentionPolicy;

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RocketMessageListener {

    String nameServer() default "${deppon.rocket.name-server:}";

    String consumerGroup();

    String topic();

    int consumeThreadMax() default 64;

    long consumeTimeout() default 30000L;

    String accessKey() default "${deppon.rocket.consumer.access-key:}";

    String secretKey() default "${deppon.rocket.consumer.secret-key:}";

    boolean enableMsgTrace() default true;

    ConsumeMode consumeMode();

    MessageModel messageModel();

    String accessChannel() default "${deppon.rocket.access-channel:}";

}
